Syntax: SELECT TOP n select_list FROM T Get top n records FROM T Get top n records from each group according to ortop, limit, offset
Decription: Set offset(s) for specified partition(s) of the current topic in a consumer group. Syntax: kafka_offset(fd, consumer group, topic partition, offset